package cn.mn.ac.rocketmq.annotation;

import com.aliyun.openservices.shade.com.alibaba.rocketmq.common.protocol.heartbeat.MessageModel;
import org.springframework.stereotype.Component;

import java.lang.annotation.*;

/**
 * @author hefulin
 */
@Documented
@Component
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface ConsumerListener {

    /**
     * 绑定的主题
     */
    String topic();

    /**
     * 绑定的消费组
     */
    String group();

    /**
     * consumer 注册的 接受消息的过滤tag
     */
    String[] tags() default "";

    /**
     * 消费模式
     */
    MessageModel messageModel() default MessageModel.CLUSTERING;

    /**
     * 开启线程数
     */
    int threadNums() default 0;

    /**
     * 消费者启动个数
     */
    int nums() default 0;


    /**
     * 容器名
     */
    String value() default "";


}
